package com.dabai.iot.mqtt.config;

import io.vertx.core.Vertx;
import io.vertx.core.VertxOptions;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Vert.x 实例配置类
 *
 * @author kev1n
 */
@Configuration
public class VertxConfig {

    @Bean
    public Vertx vertx() {
        VertxOptions options = new VertxOptions()
            .setEventLoopPoolSize(VertxOptions.DEFAULT_EVENT_LOOP_POOL_SIZE)  // 设置事件循环线程池大小
            .setWorkerPoolSize(VertxOptions.DEFAULT_WORKER_POOL_SIZE);        // 设置工作线程池大小
        return Vertx.vertx(options);
    }

}
